package cn.com.demo.kafka;

public class Config {
     public static final String BOOTSTRAP_SERVERS_CONFIG = "127.0.0.1:9092";
    public static final String TOPIC = "test";
    public static final String GROUP_ID_CONFIG = "zd";
    public static final  int PRODUCER_SEND_INTERVAL = 2000;
    public static final  int CONSUMER_POLL_MSG_INTERVAL = 2000;
    public static final  int CONSUMER_DEAL_MSG_INTERVAL = 500;
}
